package com.qf.driver.mqtt.handler;

import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

/**
 * 向emqx服务器发送指令
 * mqttOutputChannel通道对象在MqttConfig初始化类中进行了初始化,
 * 在这里使用输出通道发送指令
 * @author 千锋健哥
 */
@MessagingGateway(defaultRequestChannel = "mqttOutputChannel")
public interface MqttSendHandler {

    /**
     * 发送指令给emqx服务器
     * @param topic  主题
     * @param qos    级别
     * @param data   数据指令, json格式字符串
     */
    public void sendToMqtt(@Header(MqttHeaders.TOPIC) String topic, @Header(MqttHeaders.QOS)Integer qos, String data);
}
